//引入express模块
const express=require('express');
//引入mysql连接池对象
const pool=require('../pool.js');

//创建路由器
let router=express.Router();

//挂载路由
//1、用户登录
router.get('/v1/login/:sname&:spwd',(req,res)=>{
	//接收参数
	var $sname=req.params.sname;
	var $spwd=req.params.spwd;
	var sql='select * from staff where sname=? and spwd=?';
	pool.query(sql,[$sname,$spwd],(err,result)=>{
		if(err) throw err;
		if(result.length>0){
			res.send('1');//成功
		}else{
			res.send('0');//失败
		}
	});
});
// 员工注册
// 根据sname查询用户
router.get('/v1/queryUser/:sname',(req,res)=>{
	var $sname=req.params.sname;
	var sql='select * from staff where sname=?';
	pool.query(sql,[$sname],(err,result)=>{
		if(err) throw err;
		if(result.length>0){
			res.send('1');//查询用户成功
		}else{
			res.send('0');//查询用户失败
		}
	});
});
// 注册
router.post('/v1/reg',(req,res)=>{
	var obj=req.body;
	var sql='insert into staff set ?';
	pool.query(sql,[obj],(err,result)=>{
		if(err) throw err;
		if(result.affectedRows>0){
			res.send('1');//用户注册成功
		}else{
			res.send('0');//用户注册失败
		}
	});
});

//2、根据委托单编号sheet_id查询样品信息
router.get('/v1/query/:sheet_id',(req,res)=>{
	var $sheet_id=req.params.sheet_id;
	var sql='select * from sample where sheet_id=?';
	pool.query(sql,[$sheet_id],(err,result)=>{
		if(err) throw err;
		if(result.length>0){
			res.send('1');//成功
		}else{
			res.send('0');//失败
		}
	});
});

//3、样品注册
router.post('/v1/regsample',(req,res)=>{
	var obj=req.body;
	console.log(obj);
	var sql='insert into sample set?';
	pool.query(sql,[obj],(err,result)=>{
		if(err) throw err;
		console.log(result);
		if(result.affectedRows>0){
			res.send('1');//样品注册成功
		}else{
			res.send('0');//样品注册失败
		}
	});
});

//4、获取用户列表
router.get('/v1/userlist/',(req,res)=>{
	var sql='select * from staff';
	pool.query(sql,(err,result)=>{
		if(err) throw err;
		res.send(result);
	});
});

//5、删除员工
router.delete('/v1/del/:sid',(req,res)=>{
	var $sid=req.params.sid;
	var sql='delete from staff where sid=?';
	pool.query(sql,[$sid],(err,result)=>{
		if(err) throw err;
		if(result.affectedRows>0){
			res.send('1');//成功
		}else{
			res.send('0');//失败
		}
	});
});

//6、根据sid查询员工信息
router.get('/v1/search/:sid',(req,res)=>{
	var $sid=req.params.sid;
	var sql='select * from staff where sid=?';
	pool.query(sql,[$sid],(err,result)=>{
		if(err) throw err;
		if(result.length>0){
			res.send(result);//成功
		}else{
			res.send('0');//失败
		}
	});
});

//7、根据sid修改员工信息
router.put('/v1/update',(req,res)=>{
	//获取用户输入的信息 
	var obj=req.body;
	var sql='update staff set ? where sid=?';
	pool.query(sql,[obj,obj.sid],(err,result)=>{
		if(err) throw err;
		if(result.affectedRows>0){
			console.log(result);
			res.send("1");//成功
		}else{
			res.send('0');//失败
		}
	});
});


//7、获取常规检测参数
router.get('/v1/basiclist/',(req,res)=>{
	var sql='select * from basic_check';
	pool.query(sql,(err,result)=>{
		if(err) throw err;
		res.send(result);
	});
});
//7、获取专项检测参数
router.get('/v1/speciallist/',(req,res)=>{
	var sql='select * from special_check';
	pool.query(sql,(err,result)=>{
		if(err) throw err;
		res.send(result);
	});
});
//7、获取综合检测参数
router.get('/v1/unionlist/',(req,res)=>{
	var sql='select * from union_check';
	pool.query(sql,(err,result)=>{
		if(err) throw err;
		res.send(result);
	});
});

//7、获取任务列表
router.get('/v1/worklist/:start&:count',(req,res)=>{
	var $start=req.params.start;
	var $count=req.params.count;
	$start=parseInt($start);
	$count=parseInt($count);
	var sql='select * from sample limit ?,?';
	pool.query(sql,[$start,$count],(err,result)=>{
		if(err) throw err;
		res.send(result);
	});
});

//导出路由器对象
module.exports=router;







